#include "app_mqtt.h"
#include "log/log.h"
#include <unistd.h>

static int handle_callback(char *json) {
    log_debug("处理接收到远程消息：%s", json);
    return 0;
}

int main(int argc, char const *argv[])
{
    // 初始化
    app_mqtt_init();

    // 注册一个接收处理远程消息的回调函数
    app_mqtt_registerRecvCallback(handle_callback);

    // 发送消息
    app_mqtt_send("{\"conn_type\":1, \"id\": \"5758\", \"msg\": \"6162\"}");

    // 休息50s
    sleep(50);

    // 关闭
    app_mqtt_close();

    return 0;
}
